2ce2fda5b7f688f1c5fa9e10f7c8ff64ce99be12,gora-core/src/examples/java/org/apache/gora/examples/spark/SparkWordCount.java,SparkWordCount,wordCount,#DataStore#DataStore#,71
Before Change
JavaPairRDD<String, Long> reducedGoraRdd = JavaPairRDD.fromJavaRDD(mappedGoraRdd).reduceByKey(redFunc);
//Print output for debug purpose
System.out.println("SparkWordCount debug purpose TokenDatum print starts:");
Map<String, Long> tokenDatumMap = reducedGoraRdd.collectAsMap();
for (String key : tokenDatumMap.keySet()) {
System.out.println(key);
System.out.println(tokenDatumMap.get(key));
}
System.out.println("SparkWordCount debug purpose TokenDatum print ends:");
//
After Change
Map<String, Long> tokenDatumMap = reducedGoraRdd.collectAsMap();
for (String key : tokenDatumMap.keySet()) {
log.info(key);
log.info(tokenDatumMap.get(key).toString());
}
log.info("SparkWordCount debug purpose TokenDatum print ends:");
//